package com.yifeng.repo.flink.data.transport.dto;

import java.util.Map;
import java.util.Objects;

/**
 * cdc增量数据结构
 * @author lijing
 * @since 2023-01-29
 */
public class IncreDataPacket {
	private String op;

	private Map<String, Object> before;

	private Map<String, Object> after;

	private Source source;

    private Long  ts_ms;

	public String getOp() {
		return op;
	}

	public void setOp(String op) {
		this.op = op;
	}

	public Map<String, Object> getBefore() {
		return before;
	}

	public void setBefore(Map<String, Object> before) {
		this.before = before;
	}

	public Map<String, Object> getAfter() {
		return after;
	}

	public void setAfter(Map<String, Object> after) {
		this.after = after;
	}

	public Source getSource() {
		if(Objects.isNull(source)) {
			return new Source();
		}
		return source;
	}

	public void setSource(Source source) {
		this.source = source;
	}

	public Long getTs_ms() {
		return ts_ms;
	}

	public void setTs_ms(Long ts_ms) {
		this.ts_ms = ts_ms;
	}
   
}
